package com.cskaoyan.com.collection.blockingqueue;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;

public class DemoBlockingQueue1 {
    public static void main(String[] args) throws InterruptedException {

//  1, 什么是BlockingQueue?
//    阻塞队列
//    是一个大小容量有限的队列 (不可以扩容)
//    1, 当我们在这个阻塞队列添加数据的时候, 添加满了, 添加线程等待
//    2, 当我们在这个阻塞队列删除数据的时候, 队列空了, 删除线程等待

//        2, BlockingQueue的阻塞方法?
//    put: 添加数据(阻塞方法)
//    take: 删除数据(阻塞方法)


        BlockingQueue<String>  blockingQueue = new ArrayBlockingQueue<>(2);

        blockingQueue.offer("zs");
        blockingQueue.offer("ls");

        blockingQueue.put("wu");

        System.out.println(blockingQueue);

    }
}
